package com.yyy.modules;

import com.yyy.common.Interceptors.IMsgCallbackHandler;
import com.yyy.common.annotation.CallbackHandler;
import com.yyy.entity.Message;

/**
 * @author yyy
 * @Date 2020-11-15 21:13
 * @Email yangyouyuhd@163.com
 */
@CallbackHandler(name = "queue00")
public class DefaultMsgCallbackHandler implements IMsgCallbackHandler {

    @Override
    public void returnCallback(Message msg) {
        System.out.println("消费成功回调");
    }

    @Override
    public void afterCallback(Message msg,Exception e) {
        System.out.println("消费失败回调");
    }
}
